Connecting to MariaDB via Java

This article shows the example Java code for connecting to MariaDB.

Before you start, you need to add MariaDB connector package to your Java project. The download link for MariaDB connector is https://mariadb.com/kb/en/about-mariadb-connector-j/.

package mariadb_connection;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class MariadbConnection {

    public static void main(String[] args) {
        Connection conn = null;
        String dbServer = "mariadb-xxxxx-0.cloudclusters.net"; // change it to your database server name
        int dbPort = 4229; // change it to your database server port
        String dbName = "your database name";
        String userName = "your database user name";
        String password = "your database password";
        String url = String.format("jdbc:mariadb://%s:%d/%s?user=%s&password=%s", 
                                    dbServer, dbPort, dbName, userName, password);
        try {

            conn = DriverManager.getConnection(url);
            Statement stmt = conn.createStatement();

            // create table
            String sql = "create table teacher(NO char(20), name varchar(20),primary key(NO))";
            int result = stmt.executeUpdate(sql);

            // insert data
            if (result != -1) {
                sql = "insert into teacher(NO,name) values('202001','ben')";
                result = stmt.executeUpdate(sql);
                sql = "insert into teacher(NO,name) values('202002','ethan')";
                result = stmt.executeUpdate(sql);
            }

            // query data
            sql = "select * from teacher";
            ResultSet rs = stmt.executeQuery(sql);
            System.out.println("No.\tName");
            while (rs.next()) {
                System.out.println(rs.getString(1) + "\t" + rs.getString(2));
            }
        } catch (SQLException e) {
            System.out.println("MariaDB connection had an exception");
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

}